package com.yeeyk.shell.common;

import  com.yeeyk.shell.entity.RawXlsRom;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;

/**
 * Created by zhangjuntao on 2017/3/24.
 */
public class Constants {

    /**
     * 将excel存放的信息
     */
    public  static Set<RawXlsRom> RAW_EXCEL_SET  = ConcurrentHashMap.<RawXlsRom>newKeySet();

    /**
     * 存放处理过email的壳
     */
    public  static Set<RawXlsRom> TREATED_EXCEL_SET  = ConcurrentHashMap.<RawXlsRom>newKeySet();

    /**
     *
     */
    public  static Set<RawXlsRom> TREATED_EMAIL_SET  = ConcurrentHashMap.<RawXlsRom>newKeySet();

    /**
     *
     */
    public  static Set<RawXlsRom> TREATED_CFT_SET  = ConcurrentHashMap.<RawXlsRom>newKeySet();


    public  static Set<RawXlsRom> TREATED_ALL_SET  = ConcurrentHashMap.<RawXlsRom>newKeySet();


    /**
     * 1、整个流程执行完毕后，才会将该值为true。
     * 2、当CAN_UPDATE_SHELL为false，所有消费者线程一直阻塞。
     * 3、当CAN_UPDATE_SHELL为false，消费者一直从队列中拿出rom消费。
     * 4、当最后处理完成的，和无效的都放到TREATED_ALL_SET中。
     */
    public  static AtomicBoolean CAN_UPDATE_SHELL = new AtomicBoolean(Boolean.TRUE);







}



